//package com.system.config;
//
//import org.apache.kafka.clients.admin.NewTopic;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//import com.system.constants.QueueConstant;
//
//@Configuration
//public class KafkaInitialConfig {
//
//	/***
//	 * 创建TopicName为proc_price_topic的Topic并设置分区数为3以及副本数为3
//	 * 通过bean创建(bean的名字为initialProcPriceTopic)
//	 * @return
//	 */
//	@Bean
//	public NewTopic initialProcPriceTopic() {
//		return new NewTopic(QueueConstant.PROC_PRICE_TOPIC, 3, (short) 3);
//	}
//
//	@Bean
//	public NewTopic initialRequestErrorMailTopic() {
//		return new NewTopic(QueueConstant.REQUEST_ERRORMAIL_TOPIC, 3, (short) 3);
//	}
//
//	@Bean
//	public NewTopic initialRequestLogTopic() {
//		return new NewTopic(QueueConstant.REQUEST_LOG_TOPIC, 3, (short) 3);
//	}
//}
